package com.demo.synchronized_;

/**
 * 实现 Runnable 接口 模拟卖票问题
 *
 * @author gy
 * @date 2022/4/21
 */
public class SellTicket2 {
    public static void main(String[] args) {
        SellTicket02 sellTicket02 = new SellTicket02();
        Thread thread01 = new Thread(sellTicket02);
        Thread thread02 = new Thread(sellTicket02);
        Thread thread03 = new Thread(sellTicket02);
        thread01.start();
        thread02.start();
        thread03.start();
    }
}

class SellTicket02 implements Runnable {
    /**
     *  此处无需使用静态，因为使用 实现Runnable接口方式，
     *  只创建一个对象 ，多个线程共享一个对象资源
      */
    private int ticketNum = 100;
    /**
     *  用来控制卖票线程的终止
      */
    private boolean loop = true;

    private Object object = new Object();

    @Override
    public void run() {
        // while 语句 可以使多个线程能够进来卖票
        while (loop){
            // 同步方法，同一时刻只会有一个线程进去操作资源
           sell();
        }
    }

    /**
     * 此时 synchronized 这把互斥锁 是加在 类对象 SellTicket02.class 上面的
     */
    public synchronized static void m1(){

    }

    public static void m2(){
        synchronized (SellTicket2.class) {
            System.out.println("m2");
        }
    }

    private /*synchronized*/ void sell() {
        System.out.println("开始卖票了");
        // 此时 synchronized 互斥锁 还是加载 this 对象上的
        // 解释了 这把锁可以上在其他对象上 ，只要保证是 同一个对象上即可
        synchronized (/*this*/ object) {
//            System.out.println("======="+object.hashCode());
            if (ticketNum <= 0) {
                System.out.println("票卖光了");
                loop = false;
                return;
            }
            try {
                Thread.sleep(50);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println("窗口" + Thread.currentThread().getName() + "售出一张票" + "剩余票数" + (--ticketNum));
        }
    }


}
